🖤 03. 스트림 (Stream) | 특징 | 중간연산 | 최종연산

😁 Stream은 자바 8 API 에서 새로 추가된 기능이다. 데이터 컬렉션 반복을 멋지게 처리하는 기능이며 멀티스레드 코드를 구현하지 않아도 데이터를 투명하게 병렬로 처리할 수 있다.

아래 간단한 예제를 살펴보자 !

🍽️ Dish 클래스

package javaStudy.mda04;

public class Dish {

    String name;

    int calories;

    public Dish(String name, int calories) {
        this.name = name;
        this.calories = calories;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public int getCalories() {
        return calories;
    }

    public void setCalories(int calories) {
        this.calories = calories;
    }

    @Override
    public String toString() {
        return "Dish{" +
                "name='" + name + '\'' +
                ", calories=" + calories +
                '}';
    }
}

package javaStudy.mda04;

import java.util.Arrays;
import java.util.List;

public class StreamTest {

    public static void main(String[] args) {
        List<Dish> dishList = Arrays.asList(
                new Dish("fish", 200),
                new Dish("candy", 50),
                new Dish("pasta", 500)
        );
    }
}

이제 접시 목록을 만들어서 저칼로리인 음식의 이름을 뽑아내보자.

💎 기존 코드 (JAVA 7)

// 저칼로리 음식 분류
List<Dish> lowCaloricDishes = new ArrayList<>();
for (Dish dish : dishList) {
    if (dish.getCalories() < 400) {
        lowCaloricDishes.add(dish);
    }
}

// 익명 클래스로 요리 정렬
// [Dish{name='candy', calories=50}, Dish{name='fish', calories=200}]
Collections.sort(lowCaloricDishes, new Comparator<Dish>() {
    @Override
    public int compare(Dish o1, Dish o2) {
        return Integer.compare(o1.getCalories(), o2.getCalories());
    }
});

// 정렬된 리스트 처리하여 이름 선택
// [candy, fish]
List<String> lowCaloricDishesName = new ArrayList<>();
for (Dish dish : lowCaloricDishes) {
    lowCaloricDishesName.add(dish.getName());
}

💎 최신 코드 (JAVA 8)

// [candy, fish]
List<String> lowCaloricDishesName2 =
                dishList.stream()
                .filter(d -> d.getCalories() < 400)
                .sorted(Comparator.comparing(Dish::getCalories))
                .map(Dish::getName)
                .collect(toList());

.. 엄청 깔끔하긴 하다.

🍽️ 새로운 Dish 클래스

앞으로는 아래 Dish 클래스와 menu 를 주요 예제로 사용하도록 한다.

package javaStudy.mda04;

public class Dish {

    private final String name;
    private final boolean vegetarian;
    private final int calories;
    private final Type type;

    public Dish(String name, boolean vegetarian, int calories, Type type) {
        this.name = name;
        this.vegetarian = vegetarian;
        this.calories = calories;
        this.type = type;
    }

    public String getName() {
        return name;
    }

    public boolean isVegetarian() {
        return vegetarian;
    }

    public int getCalories() {
        return calories;
    }

    public Type getType() {
        return type;
    }

    public enum Type {
        MEAT,
        FISH,
        OTHER
    }

    @Override
    public String toString() {
        return "Dish{" +
                "name='" + name + '\'' +
                ", vegetarian=" + vegetarian +
                ", calories=" + calories +
                ", type=" + type +
                '}';
    }
}

package javaStudy.mda04;

import java.util.Arrays;
import java.util.List;

public class MainMethod2 {

    public static List<Dish> menu = Arrays.asList(
            new Dish("pork", false, 800, Dish.Type.MEAT),
            new Dish("beef", false, 700, Dish.Type.MEAT),
            new Dish("chicken", false, 400, Dish.Type.MEAT),
            new Dish("french fries", true, 530, Dish.Type.OTHER),
            new Dish("rice", true, 350, Dish.Type.OTHER),
            new Dish("season fruit", true, 120, Dish.Type.OTHER),
            new Dish("pizza", true, 550, Dish.Type.OTHER),
            new Dish("prawns", false, 300, Dish.Type.FISH),
            new Dish("salmon", false, 450, Dish.Type.FISH)
    );

    public static void main(String[] args) {

    }
}

💎 스트림의 특징

// [pork, beef, chicken]
List<String> threeHighCaloricDishnames =
            menu.stream()
            .filter(dish -> dish.getCalories() > 300)
            .map(Dish::getName)
            .limit(3)
            .collect(toList());

요리 리스트를 포함하는 menu에 stream 메소드를 호출해서 스트림을 얻었다.

여기서 데이터 소스는 요리 리스트다.

데이터 소스는 연속된 요소를 스트림에 제공한다.

다음으로 스트림에 filter map limit collect로 이어지는 일련의 데이터 처리 연산을 적용한다.

이때, collect를 제외한 모든 연산은 서로 파이프라인을 형성할 수 있도록 스트림을 반환한다.

마지막으로 collect 연산으로 파이프라인을 처리해서 결과를 반환한다.

collect를 호출하기 전까지는 menu에서 무엇도 선택되지 않으며 출력 결과도 없다.

💎 중간연산

연산	형식	반환 형식	연산의 인수	함수 디스크립터
filter	중간 연산	Stream<T>	Predicate<T>	T -> boolean
map	중간 연산	Stream<R>	Function<T, R>	T -> R
limit	중간 연산	Stream<T>	-	-
sorted	중간 연산	Stream<T>	Comparator<T>	(T, T) -> int
distinct	중간 연산	Stream<T>	-	-

💎 최종 연산

연산	형식	반환 형식	목적
forEach	최종 연선	void	스트림의 각 요소를 소비하면서 람다를 적용한다.
count	최종 연산	long(generic)	스트림의 요소 개수를 반환한다.
collect	최종 연산	-	스트림을 리듀스해서 리스트, 맵, 정수 형식의 컬렉션을 만든다.

Reference

---

모던 자바 인 액션 (한빛미디어)